<?php
// 这个文件是配送系统处理队列中的订单并进行标记的一个文件
include '../include/db.php';
$db = DB::getIntance();
$table = 'order_queue';

// 1.先要把处理的记录更新为等待处理
$waiting = ['status'=>0];
$lock = ['status'=>2];
$res_lock = $db->update($table,$lock,$waiting,12);

if ( ! $res_lock){
    exit('ALL Finished');
}

// 2.选择出刚刚更新的这些数据，然后进行配送系统的处理
    // 2.1.选择出要处理的订单的内容
$res = $db->selectAll($table, $lock);

    // 2.2.然后由配货系统进行配货处理
    // ......

// 3.把这些处理过的程序更新为已完成
$success = [
    'status'=>1,
    'updated_at'=>date('Y-m-d H:i:s')
];
$res_last = $db->update($table, $success, $lock);
if ($res_last){
    exit('Success:'.$res_last);
}
exit('Fail:'.$res_last);